

package com.soso.base.google.mq;


/**
 * 
 * @author speed
 *
 */
public interface MessageQueue {
	
	void publish(Message message);
	void purge(Message message); 

	void subscribe(Enum<?> topic, Class<?> subscriber);

	void subscribe(String topic, Class<?> subscriber);

	void unsubscribe(String topic, Class<?> subscriber);
	
	void execute(Message message);
	
}
